package com.dawn.websocket.server.server;

import java.io.IOException;

import javax.websocket.server.ServerEndpoint;

import org.springframework.stereotype.Component;

/**
 * @ServerEndpoint 注解是一个类层次的注解，它的功能主要是将目前的类定义成一个websocket服务器端,
 * 注解的值将被用于监听用户连接的终端访问URL地址,客户端可以通过这个URL来连接到WebSocket服务器端
 */
@Component
@ServerEndpoint("/websocket")
public class WebSocketServerImpl extends BaseWebSocketServer {

    @Override
    public void dealMessage(String message) {
        // TODO: 这里自己添加标识做处理
        logger.info("接收到客户端的信息：{}", message);
        try {
            sendMessage("i had received the msg! " + message);
        } catch (IOException e) {
            logger.error("err", e);
        }
    }
}
